const WebSocket = require('ws');

// 测试定时任务是否正常工作
async function testScheduler() {
    console.log('🧪 开始测试定时任务...');

    try {
        // 连接到WebSocket，使用正确的路径
        const ws = new WebSocket('ws://localhost:3000/user-service/websocket');

        ws.on('open', () => {
            console.log('✅ WebSocket连接成功');

            // 发送测试消息
            const testMessage = {
                act_id: 1332, // 查询大小玩法信息
                data: {}
            };

            ws.send(JSON.stringify(testMessage));
            console.log('📤 发送测试消息:', testMessage);
        });

        ws.on('message', (data) => {
            try {
                const response = JSON.parse(data.toString());
                console.log('📥 收到响应:', response);

                if (response.act_id === 1332) {
                    console.log('✅ 1332接口响应正常');
                    console.log('📊 当前期数信息:', response.data);

                    // 检查期数数据是否完整
                    if (response.data.id && response.data.second !== undefined) {
                        console.log('✅ 期数数据完整');
                        console.log(`🎯 当前期数: ${response.data.id}`);
                        console.log(`⏰ 剩余时间: ${response.data.second}秒`);
                        console.log(`💰 下注统计:`, {
                            sumdagold: response.data.sumdagold,
                            sumdasliver: response.data.sumdasliver,
                            sumxiaogold: response.data.sumxiaogold,
                            sumxiaosliver: response.data.sumxiaosliver
                        });
                    } else {
                        console.log('❌ 期数数据不完整');
                    }
                }

                // 关闭连接
                setTimeout(() => {
                    ws.close();
                    console.log('🔌 WebSocket连接已关闭');
                }, 1000);

            } catch (error) {
                console.error('❌ 解析响应失败:', error);
            }
        });

        ws.on('error', (error) => {
            console.error('❌ WebSocket错误:', error);
        });

        ws.on('close', () => {
            console.log('🔌 WebSocket连接已关闭');
        });

    } catch (error) {
        console.error('❌ 测试失败:', error);
    }
}

// 运行测试
testScheduler(); 